var MongoClient = require("mongodb").MongoClient;
var url = "mongodb://localhost:27017/";

// 单个文档插入
// MongoClient.connect(url, { useNewUrlParser: true,useNewUrlParser: true,useUnifiedTopology: true }, function(err, db){
//     if (err) throw err;
//     var dbo = db.db("muzi");
//     var myobj = { name:"KBryant",type:"NBA",like:['唱','跳','rap','打铁']};
//     dbo.collection("dalao").insertOne(myobj,function(err,res){
//         if (err) throw err;
//         console.log("文档插入成功，老哥稳");
//         db.close();
//     });
// });


// 多个文档插入
// MongoClient.connect(url, { useNewUrlParser: true,useNewUrlParser: true,useUnifiedTopology: true},function (err,db) {
//     if (err) throw err;
//     var dbo = db.db("muzi");
//     var myobj = [
//         {   name:   "周杰伦",   type:"流行天王",    like:['唱','跳','rap','旅游']   },
//         {   name:   "乔丹",     type:"airjordan",   like:['唱','跳','吐舌头','卖鞋']    },
//         {   name:   "李宁",     type:"品牌",   like:['唱','跳','吊环','卖鞋']},

//     ];
//     dbo.collection("dalao").insertMany(myobj,function (err,res) {
//         if (err) throw err;
//         console.log("老哥稳！多个文档插入成功，插入文档的数量为："+ res.insertedCount);
//         db.close();
        
//     });
    
// });

// 返回数据集合
// MongoClient.connect(url, { useNewUrlParser: true,useNewUrlParser: true,useUnifiedTopology: true},function (err,db) {
//     if (err) throw err;
//     var dbo = db.db("muzi");
//     // var myobj = [
//     //     {   name:   "周杰伦",   type:"流行天王",    like:['唱','跳','rap','旅游']   },
//     //     {   name:   "乔丹",     type:"airjordan",   like:['唱','跳','吐舌头','卖鞋']    },
//     //     {   name:   "李宁",     type:"品牌",   like:['唱','跳','吊环','卖鞋']},

//     // ];
//     dbo.collection("dalao").find({}).toArray(function (err,result) {
//         if (err) throw err;
//         console.log(result);
//         db.close();
//     });
// });

// 查找
// MongoClient.connect(url, { useNewUrlParser: true,useNewUrlParser: true,useUnifiedTopology: true},function (err,db) {
//     if (err) throw err;
//     var dbo = db.db("muzi");
//     // 第一种方式👇:
//     // var whereStr = {"username":'马斯克'};

//     // 第二种方式👇:
//     var whereStr = {"type":{
//         $in:['NBA']
//     }};
//     dbo.collection("dalao").find(whereStr).toArray(function (err,result) {
//         if (err) throw err;
//         console.log(result);
//         db.close();
//     });
// });

// 更新一条数据
// MongoClient.connect(url, { useNewUrlParser: true,useNewUrlParser: true,useUnifiedTopology: true},function (err,db) {
//     if (err) throw err;
//     var dbo = db.db("muzi");
//     var whereStr = {"name":'李宁'}; // 查询条件
//     var updateStr = {$set:{"type":'卖鞋的'}}; // 修改参数
//     dbo.collection("dalao").updateOne(whereStr,updateStr,function (err,res) {
        
//         if (err) throw err;
//         console.log("老哥稳！修改成功!");
//         db.close();
//     });
// });

// 更新多条数据

MongoClient.connect(url, { useNewUrlParser: true,useNewUrlParser: true,useUnifiedTopology: true},function (err,db) {
    if (err) throw err;
    var dbo = db.db("muzi");
    var whereStr = {"name":'李宁'}; // 查询条件
    var updateStr = {$set:{"name":'安踏'}}; // 修改参数
    dbo.collection("dalao").updateMany(whereStr,updateStr,function (err,res) {
        if (err) throw err;
        console.log("老哥稳！修改成功!",res.result.nModified+"条文档被更新"); //设置更新提醒
        db.close();
    });
});

